package com.ot.flink.cdc.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * 配置信息
 * @author: admin
 * @date: 2024/5/24
 * @since JDK1.8 version: 1.0.0
 */
@Component
public class CdcTargetConfig {

    @Value("${ot.cdc.target.type}")
    private String type;

    @Value("${ot.cdc.target.kafka.hosts}")
    private String kafkaHosts;

    @Value("${ot.cdc.target.kafka.topic}")
    private String kafkaTopic;

    @Value("${ot.cdc.target.kafka.mechanism:}")
    private String kafkaMechanism;

    @Value("${ot.cdc.target.kafka.config:}")
    private String kafkaConfig;

    @Value("${ot.cdc.target.kafka.protocol:}")
    private String kafkaProtocol;

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getKafkaHosts() {
        return kafkaHosts;
    }

    public void setKafkaHosts(String kafkaHosts) {
        this.kafkaHosts = kafkaHosts;
    }

    public String getKafkaTopic() {
        return kafkaTopic;
    }

    public void setKafkaTopic(String kafkaTopic) {
        this.kafkaTopic = kafkaTopic;
    }

    public String getKafkaMechanism() {
        return kafkaMechanism;
    }

    public void setKafkaMechanism(String kafkaMechanism) {
        this.kafkaMechanism = kafkaMechanism;
    }

    public String getKafkaConfig() {
        return kafkaConfig;
    }

    public void setKafkaConfig(String kafkaConfig) {
        this.kafkaConfig = kafkaConfig;
    }

    public String getKafkaProtocol() {
        return kafkaProtocol;
    }

    public void setKafkaProtocol(String kafkaProtocol) {
        this.kafkaProtocol = kafkaProtocol;
    }
}
